f08688a28e6c5c72b6fa6673bf13bceea3a6fc1c,src/org/jgroups/blocks/GroupRequest.java,GroupRequest,adjustMembership,#,607
Before Change
// if(log.isWarnEnabled()) log.warn("GroupRequest.adjustMembership()", "membership is null");
return;
}
for(int i=0; i < membership.length; i++) {
mbr=membership[i];
if((this.members != null && !this.members.contains(mbr))
|| suspects.contains(mbr)) {
addSuspect(mbr);
responses[i]=null;
received[i]=SUSPECTED;
}
After Change
* a the rsp_mutex locked, so this should not be a problem).
*/
private void adjustMembership() {
if(requests.size() == 0)
return;
Map.Entry entry;
Address mbr;
Rsp rsp;
for(Iterator it=requests.entrySet().iterator(); it.hasNext();) {
entry=(Map.Entry)it.next();
mbr=(Address)entry.getKey();
if((!this.members.contains(mbr)) || suspects.contains(mbr)) {
addSuspect(mbr);
rsp=(Rsp)entry.getValue();
rsp.setValue(null);
rsp.setSuspected(true);
}
}
}